Merge branch 'tamron' of http://git.xfoto.com.cn/Kodo/kodo into tamron
2 changed files with 42 additions and 2 deletions
+ 40
- 2
pre/custom_message.py
@@ -1,9 +1,13 @@ |
||
| 1 | 1 |
# -*- coding: utf-8 -*- |
| 2 | 2 |
|
| 3 |
+import logging |
|
| 4 |
+ |
|
| 3 | 5 |
from django.conf import settings |
| 4 | 6 |
from pywe_custom_message import send_custom_wxa_message |
| 5 | 7 |
from pywe_media import media_upload |
| 6 | 8 |
from pywe_storage import RedisStorage |
| 9 |
+from pywe_subscribe_message import send_wxa_subscribe_template_message |
|
| 10 |
+from pywe_template_message import send_template_message |
|
| 7 | 11 |
|
| 8 | 12 |
from utils.redis.connect import r |
| 9 | 13 |
|
@@ -11,6 +15,9 @@ from utils.redis.connect import r |
||
| 11 | 15 |
WECHAT = settings.WECHAT |
| 12 | 16 |
|
| 13 | 17 |
|
| 18 |
+logger = logging.getLogger('console')
|
|
| 19 |
+ |
|
| 20 |
+ |
|
| 14 | 21 |
def mediaupload(media_file=None, media_file_path=None): |
| 15 | 22 |
wxcfg = WECHAT.get('JSAPI', {})
|
| 16 | 23 |
|
@@ -22,12 +29,43 @@ def mediaupload(media_file=None, media_file_path=None): |
||
| 22 | 29 |
print(res) |
| 23 | 30 |
|
| 24 | 31 |
|
| 32 |
+# 发送客服消息 - 发送小程序卡片 |
|
| 25 | 33 |
def sendcustomwxamessage(openid=None, miniappid=None, pagepath=None, thumb_media_id=None, title=None): |
| 26 | 34 |
wxcfg = WECHAT.get('JSAPI', {})
|
| 27 | 35 |
|
| 28 | 36 |
appid = wxcfg.get('appID')
|
| 29 | 37 |
secret = wxcfg.get('appsecret')
|
| 30 | 38 |
|
| 31 |
- res = send_custom_wxa_message(openid=openid, miniappid=miniappid, pagepath=pagepath, thumb_media_id=thumb_media_id, title=title, appid=appid, secret=secret, token=None, storage=RedisStorage(r)) |
|
| 39 |
+ try: |
|
| 40 |
+ res = send_custom_wxa_message(openid=openid, miniappid=miniappid, pagepath=pagepath, thumb_media_id=thumb_media_id, title=title, appid=appid, secret=secret, token=None, storage=RedisStorage(r)) |
|
| 41 |
+ print(res) |
|
| 42 |
+ except Exception as e: |
|
| 43 |
+ logger.info(e) |
|
| 32 | 44 |
|
| 33 |
- print(res) |
|
| 45 |
+ |
|
| 46 |
+# 发送模版消息 |
|
| 47 |
+def sendtemplatemessage(openid=None, template_id=None, data=None, url=None, miniappid=None, minipagepath=None): |
|
| 48 |
+ wxcfg = WECHAT.get('JSAPI', {})
|
|
| 49 |
+ |
|
| 50 |
+ appid = wxcfg.get('appID')
|
|
| 51 |
+ secret = wxcfg.get('appsecret')
|
|
| 52 |
+ |
|
| 53 |
+ try: |
|
| 54 |
+ res = send_template_message(user_id=openid, template_id=template_id, data=data, url=url, miniappid=miniappid, minipagepath=minipagepath, appid=appid, secret=secret, storage=RedisStorage(r)) |
|
| 55 |
+ print(res) |
|
| 56 |
+ except Exception as e: |
|
| 57 |
+ logger.info(e) |
|
| 58 |
+ |
|
| 59 |
+ |
|
| 60 |
+# 发送订阅消息 - 小程序 |
|
| 61 |
+def sendwxasubscribemessage(openid=None, template_id=None, data=None, miniprogram_state=None, lang=None, page=None): |
|
| 62 |
+ wxcfg = WECHAT.get('MINIAPP', {})
|
|
| 63 |
+ |
|
| 64 |
+ appid = wxcfg.get('appID')
|
|
| 65 |
+ secret = wxcfg.get('appsecret')
|
|
| 66 |
+ |
|
| 67 |
+ try: |
|
| 68 |
+ res = send_wxa_subscribe_template_message(user_id=openid, template_id=template_id, data=data, page=page, miniprogram_state=miniprogram_state, lang=lang, appid=appid, secret=secret, storage=RedisStorage(r)) |
|
| 69 |
+ print(res) |
|
| 70 |
+ except Exception as e: |
|
| 71 |
+ logger.info(e) |
+ 2
- 0
requirements_pywe.txt
@@ -8,6 +8,8 @@ pywe-marketcode==1.0.3 |
||
| 8 | 8 |
pywe-membercard==1.0.3 |
| 9 | 9 |
pywe-custom-message==1.0.1 |
| 10 | 10 |
pywe-event-message==1.0.1 |
| 11 |
+pywe-subscribe-message==1.0.0 |
|
| 12 |
+pywe-template-message==1.0.0 |
|
| 11 | 13 |
pywe-miniapp==1.1.6 |
| 12 | 14 |
pywe-oauth==1.1.1 |
| 13 | 15 |
pywe-pay==1.0.13 |